<template>
  <div class="absolute top-0 left-0 right-0 bottom-0 flex">
    <Left
      :is-writing="isWriting"
      class="h-full"
      @submit="submit"
      @reset="reset"
      @example="handleExampleClick"
    />
    <Right
      :is-writing="isWriting"
      @stop-stream="stopStream"
      ref="rightRef"
      class="flex-grow"
      v-model:content="writeResult"
    />
  </div>
</template>

<script setup lang="ts">
import { WriteApi, WriteVO } from '@/api/ai/write/write'
import * as LoginApi from '@/api/base/login'
import { WriteExample } from '@/views/ai/utils/constants'
import Left from './components/Left.vue'
import Right from './components/Right.vue'

defineOptions({ name: 'AiWrite' })

const message = useMessage()

const writeResult = ref('') // 写作结果
const isWriting = ref(false) // 是否正在写作中
const abortController = ref<AbortController>() // // 写作进行中 abort 控制器(控制 stream 写作)

/** 停止 stream 生成 */
const stopStream = () => {
  abortController.value?.abort()
  isWriting.value = false
}

/** 执行写作 */
const rightRef = ref<InstanceType<typeof Right>>()
const submit = async (data: WriteVO) => {
  abortController.value = new AbortController()
  writeResult.value = ''
  isWriting.value = true

  // 检查认证token，若失效则自动刷新或弹出登出对话框(无法刷新时)
  await LoginApi.checkAuth()

  await WriteApi.writeStream({
    data,
    onMessage: async (res) => {
      const { code, data, msg } = JSON.parse(res.data)
      if (!code?.startsWith('2')) {
        message.alert(`写作异常：${msg}`)
        stopStream()
        return
      }
      writeResult.value = writeResult.value + data
      // 滚动到底部
      await nextTick()
      rightRef.value?.scrollToBottom()
    },
    ctrl: abortController.value,
    onClose: stopStream,
    onError: (error) => {
      message.alert(`写作异常：${error.message || error}`)
      stopStream()
    }
  })
}

/** 点击示例触发 */
const handleExampleClick = (type: keyof typeof WriteExample) => {
  writeResult.value = WriteExample[type].data
}

/** 点击重置的时候清空写作的结果**/
const reset = () => {
  writeResult.value = ''
}
</script>
